package com.milo.receiver;

import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.*;
import org.springframework.stereotype.Component;

import java.io.IOException;

/**
 * 接收报名信息
 *
 * @author jiayan
 * @date 2021-6-11 16:24:00
 */
@Component
public class BidderInfoConsumer {


    /**
     * 预处理消息队列信息
     */
    @RabbitHandler
    @RabbitListener(bindings = {@QueueBinding(
            value = @Queue(value = "tenderStruct.bidder.bidderInfo", durable = "true"),
            exchange = @Exchange(value = "yunecai-exchange", type = "topic"), key = "tenderStruct.bidder.bidderInfo")})
    public void handle(Message message, Channel channel) throws IOException {

    }
}
